Skip to content

ConcurrentStatelessSignalAsync class

Defined in

Namespace: ReactiveUI.Primitives.Async.Signals Assembly: ReactiveUI.Primitives.Async.Core.dll Full name: ReactiveUI.Primitives.Async.Signals.ConcurrentStatelessSignalAsync<T> Modifiers: public sealed

Summary

View source

Represents a stateless asynchronous Signal that forwards notifications to observers concurrently.

Applies to

net10.0, net10.0-browserwasm1.0, net10.0-desktop1.0, net9.0, net9.0-browserwasm1.0, net9.0-desktop1.0, net8.0, net8.0-ios17.5, net8.0-maccatalyst17.5, net8.0-macos14.2, net8.0-macos14.5, net8.0-tvos17.2, netstandard2.1, net462, net481, net471

Class hierarchy
classDiagram
class ConcurrentStatelessSignalAsync~T~
class ISignalAsync~T~ {
    <>
}
ISignalAsync~T~ <|.. ConcurrentStatelessSignalAsync~T~
class IObserverAsync~T~ {
    <>
}
IObserverAsync~T~ <|.. ConcurrentStatelessSignalAsync~T~
class IAsyncDisposable {
    <>
}
IAsyncDisposable <|.. ConcurrentStatelessSignalAsync~T~
class IObservableAsync~T~ {
    <>
}
IObservableAsync~T~ <|.. ConcurrentStatelessSignalAsync~T~

Implements: ISignalAsync, IObserverAsync, IAsyncDisposable, IObservableAsync

Remarks

This Signal distributes notifications to all subscribed observers in parallel, allowing for improved throughput in scenarios where observer processing can occur independently. Use this type when observer notification order is not important and concurrent delivery is desired. Thread safety is ensured for concurrent observer notifications.

Constructors

NameSummary
.ctor

Methods

NameSummary
OnNextAsyncAsynchronously processes the next value in the sequence.
OnErrorResumeAsyncHandles the specified error and resumes asynchronous processing, if possible.
OnCompletedAsyncPerforms asynchronous completion logic in response to the specified result.
DisposeAsync
SubscribeAsyncSubscribes the specified asynchronous observer to receive notifications from the observable sequence.
Inherited members